package org.myfram.flink.flinkonjar.domain.process;

import org.apache.flink.api.common.functions.FilterFunction;
import org.myfram.flink.flinkonjar.domain.entity.KafkaTargetUserEvent;

public class AgeFilterFunction implements FilterFunction<KafkaTargetUserEvent> {
    @Override
    public boolean filter(KafkaTargetUserEvent user) throws Exception {
        return user.getAge() > 20;
    }
}